package com.liangsui.mss.mq.service;


import com.liangsui.mss.mq.dto.BaseMqDto;

/**
 * rocketMqService
 *
 * @author zhangjiawei
 * @email 1533167396@qq.com
 * @date 2022/12/8 17:31
 */
public interface RocketMqService {

    void sendDelay(String topic, BaseMqDto<?> data, int delayLevel);
}
